package club.vann.kafka.mock.service.strategy;

import club.vann.kafka.mock.kafka.KafkaProducer;
import club.vann.kafka.mock.service.acceptor.AcceptorService;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public abstract class StrategyAcceptorService implements AcceptorService {
  protected static final Map<String, Map<String, String>> MAPPING = new ConcurrentHashMap<>();

  protected final KafkaProducer kafkaProducer;

  protected StrategyAcceptorService(KafkaProducer kafkaProducer) {
    this.kafkaProducer = kafkaProducer;
  }
}
